package com.celeritymq.consumer;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Topic;
import javax.jms.TopicSubscriber;

import com.celeritymq.destination.CelerityTopic;

public class CelerityTopicSubscriber extends CelerityMessageConsumer implements TopicSubscriber {
	private CelerityTopic topic;
	private boolean noLocal;

	public CelerityTopicSubscriber(CelerityTopic topic, String messageSelector, boolean noLocal) {
		super(messageSelector);
		this.topic = topic;
		this.noLocal = noLocal;
	}

	@Override
	public boolean getNoLocal() throws JMSException {
		return noLocal;
	}

	@Override
	public Topic getTopic() throws JMSException {
		return topic;
	}

}
